d796ec1cb721287d6090e10b4e1c03ae53ce4a84,tests/junit/org/jgroups/tests/UNICASTTest.java,UNICASTTest,testReceptionOfAllMessages,#,65
Before Change
if(i % 1000 == 0)
System.out.println("==> " + i);
}
num_received=r.getNumberOfReceivedMessages();
System.out.println("-- num received=" + num_received);
Util.sleep(1000);
num_received=r.getNumberOfReceivedMessages();
System.out.println("-- num received=" + num_received);
assertTrue(num_received >= NUM_MSGS);
System.out.println("Stats:\n" + s.dumpStats());
}
After Change
System.out.println("==> " + i);
}
int num_tries=10;
while((num_received=r.getNumberOfReceivedMessages()) != NUM_MSGS && num_tries > 0) {
if(r.getException() != null)
throw r.getException();
Util.sleep(3000);
// System.out.println("-- num received=" + num_received);
num_tries--;
}
System.out.println("-- num received=" + num_received + ", stats:\n" + s.dumpStats());
assertTrue(num_received == NUM_MSGS);
}